diff --git a/ingest/ledger_transaction_reader.go b/ingest/ledger_transaction_reader.go
index 819930994..9f816f0ed 100644
--- a/ingest/ledger_transaction_reader.go
+++ b/ingest/ledger_transaction_reader.go
@@ -15,7 +15,7 @@ import (
 // Use NewTransactionReader to create a new instance.
 type LedgerTransactionReader struct {
 	ledgerCloseMeta xdr.LedgerCloseMeta
-	transactions    []LedgerTransaction
+	byHash          map[xdr.Hash]xdr.TransactionEnvelope
 	readIdx         int
 }
 
@@ -53,56 +53,53 @@ func (reader *LedgerTransactionReader) GetHeader() xdr.LedgerHeaderHistoryEntry
 // Read returns the next transaction in the ledger, ordered by tx number, each time
 // it is called. When there are no more transactions to return, an EOF error is returned.
 func (reader *LedgerTransactionReader) Read() (LedgerTransaction, error) {
-	if reader.readIdx < len(reader.transactions) {
+	if reader.readIdx < len(reader.byHash) {
+		i := reader.readIdx
+		hash := reader.ledgerCloseMeta.TransactionHash(i)
+		envelope, ok := reader.byHash[hash]
+		if !ok {
+			hexHash := hex.EncodeToString(hash[:])
+			return LedgerTransaction{}, errors.Errorf("unknown tx hash in LedgerCloseMeta: %v", hexHash)
+		}
+
+		// We check the version only if FeeProcessing are non empty because some backends
+		// (like HistoryArchiveBackend) do not return meta.
+		if reader.ledgerCloseMeta.ProtocolVersion() < 10 && reader.ledgerCloseMeta.TxApplyProcessing(i).V < 2 &&
+			len(reader.ledgerCloseMeta.FeeProcessing(i)) > 0 {
+			return LedgerTransaction{}, errors.New(
+				"TransactionMeta.V=2 is required in protocol version older than version 10. " +
+					"Please process ledgers again using the latest stellar-core version.",
+			)
+		}
+
 		reader.readIdx++
-		return reader.transactions[reader.readIdx-1], nil
+		return LedgerTransaction{
+			Index:         uint32(i + 1), // Transactions start at '1'
+			Envelope:      envelope,
+			Result:        reader.ledgerCloseMeta.TransactionResultPair(i),
+			UnsafeMeta:    reader.ledgerCloseMeta.TxApplyProcessing(i),
+			FeeChanges:    lcm.FeeProcessing(i),
+			LedgerVersion: uint32(reader.ledgerCloseMeta.LedgerHeaderHistoryEntry().Header.LedgerVersion),
+		}, nil
 	}
 	return LedgerTransaction{}, io.EOF
 }
 
-// Rewind resets the reader back to the first transaction in the ledger
-func (reader *LedgerTransactionReader) Rewind() {
-	reader.readIdx = 0
+// Seek moves the reader to the given position
+func (reader *LedgerTransactionReader) Seek(index int) {
+	reader.readIdx = index
 }
 
 // storeTransactions maps the close meta data into a slice of LedgerTransaction structs, to provide
 // a per-transaction view of the data when Read() is called.
 func (reader *LedgerTransactionReader) storeTransactions(lcm xdr.LedgerCloseMeta, networkPassphrase string) error {
-	byHash := map[xdr.Hash]xdr.TransactionEnvelope{}
+	reader.byHash = map[xdr.Hash]xdr.TransactionEnvelope{}
 	for i, tx := range lcm.TransactionEnvelopes() {
 		hash, err := network.HashTransactionInEnvelope(tx, networkPassphrase)
 		if err != nil {
 			return errors.Wrapf(err, "could not hash transaction %d in TxSet", i)
 		}
-		byHash[hash] = tx
-	}
-
-	for i := 0; i < lcm.CountTransactions(); i++ {
-		hash := lcm.TransactionHash(i)
-		envelope, ok := byHash[hash]
-		if !ok {
-			hexHash := hex.EncodeToString(hash[:])
-			return errors.Errorf("unknown tx hash in LedgerCloseMeta: %v", hexHash)
-		}
-
-		// We check the version only if FeeProcessing are non empty because some backends
-		// (like HistoryArchiveBackend) do not return meta.
-		if lcm.ProtocolVersion() < 10 && lcm.TxApplyProcessing(i).V < 2 &&
-			len(lcm.FeeProcessing(i)) > 0 {
-			return errors.New(
-				"TransactionMeta.V=2 is required in protocol version older than version 10. " +
-					"Please process ledgers again using the latest stellar-core version.",
-			)
-		}
-
-		reader.transactions = append(reader.transactions, LedgerTransaction{
-			Index:         uint32(i + 1), // Transactions start at '1'
-			Envelope:      envelope,
-			Result:        lcm.TransactionResultPair(i),
-			UnsafeMeta:    lcm.TxApplyProcessing(i),
-			FeeChanges:    lcm.FeeProcessing(i),
-			LedgerVersion: uint32(lcm.LedgerHeaderHistoryEntry().Header.LedgerVersion),
-		})
+		reader.byHash[hash] = tx
 	}
 	return nil
 }
@@ -111,6 +108,6 @@ func (reader *LedgerTransactionReader) storeTransactions(lcm xdr.LedgerCloseMeta
 // helpful when there are still some transactions available so reader can stop
 // streaming them.
 func (reader *LedgerTransactionReader) Close() error {
-	reader.transactions = nil
+	reader.byHash = nil
 	return nil
 }